//package com.neusoft.javafeatures9.juc.collections;
//
//import java.util.*;
//import java.util.concurrent.*;
//
//public class CollectionsExample {
//    public static void main(String[] args) {
//        CopyOnWriteArrayList<String> list = new CopyOnWriteArrayList<>();
//        list.add("ab");
//        list.add("cd");
//        list.add("ef");
//        list.toString();
//
//        ArrayList<String> myList = new ArrayList<>();
//        myList.add("");
//        myList.toString();
//
//        CopyOnWriteArrayList copyOnWriteArrayList = new CopyOnWriteArrayList();
//        copyOnWriteArrayList.add("");
//
//        CompletionStage stage;
//        CompletionService service;
//
//        CompletableFuture future = CompletableFuture.runAsync(() -> {}).thenRun();
//
//        Executors.newFixedThreadPool();
//
//        Executor result = new ThreadPoolExecutor(, , , , , );
//
//        CompletableFuture.runAsync();
//
//
//        ForkJoinPool a;
//        Executors.newSingleThreadExecutor();
//        CompletableFuture.runAsync(() -> {}, null).thenRun();
//
//
//        SubmissionPublisher submissionPublisher = new SubmissionPublisher();
//        submissionPublisher.subscribe(new Flow.Subscriber<String>() {
//            @Override
//            public void onSubscribe(Flow.Subscription subscription) {
//                subscription.request(Long.MAX_VALUE);
//            }
//
//            @Override
//            public void onNext(String s) {
//
//            }
//
//            @Override
//            public void onError(Throwable throwable) {
//
//            }
//
//            @Override
//            public void onComplete() {
//
//            }
//        });
//        RecursiveTask<Integer> task = new RecursiveTask<Integer>() {
//            @Override
//            protected Integer compute() {
//                return 0;
//            }
//        };
//    }
//}
//
